package com.eeboot.util;

import java.util.Properties;

public class KafKaUtil {

    public static Properties genKafkaProperties(String bootstrapServers, String zookeeperConnect, String groupId){
        Properties props = new Properties();
        props.put("bootstrap.servers", bootstrapServers);
        props.put("zookeeper.connect", zookeeperConnect);
        props.put("group.id", groupId);
        props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        props.put("auto.offset.reset", "latest");
        return props;
    }

}
